home *** CD-ROM | disk | FTP | other *** search
/ Amiga Plus 1996 #5 / Amiga Plus CD - 1996 - No. 5.iso / pd / texte / thor_api / parsemsg / parsemsg.c < prev    next >
C/C++ Source or Header  |  1995-08-20  |  29KB  |  1,254 lines
  1. /* parsemsg.c
  2.     Auto: smake -f src:bbsread/parsemsg/makefile
  3. */
  4.  
  5. #include <exec/types.h>
  6. #include <exec/memory.h>
  7. #include <exec/nodes.h>
  8. #include <exec/lists.h>
  9. #include <exec/semaphores.h>
  10. #include <libraries/dos.h>
  11. #include <dos/dostags.h>
  12. #include <utility/tagitem.h>
  13. #include <utility/date.h>
  14. #include <proto/exec.h>
  15. #include <proto/dos.h>
  16. #include <proto/utility.h>
  17.  
  18. #include <string.h>
  19. #include <stdlib.h>
  20. #include <ctype.h>
  21.  
  22. #include    <libraries/bbsread.h>
  23. #include <proto/bbsread.h>
  24.  
  25. #include <libraries/utgui.h>
  26. #include <proto/utgui.h>
  27.  
  28. #include <libraries/reqtools.h>
  29. #include <proto/reqtools.h>
  30.  
  31. #define ULONG_MAX        4294967295
  32. #define BUFLEN            250
  33. #define GRABLEN        100
  34. #define NAMELENGTH    31
  35. #define CSI "\x9b"
  36.  
  37. /*  Global structure to hold librarybases  */
  38. struct TaskData
  39. {
  40.     struct ExecBase *SysBase;
  41.     struct DosLibrary *DOSBase;
  42.     struct Library *UtilityBase;
  43.     struct Library *BBSReadBase;
  44.     struct Library *UTGuiBase;
  45.     struct BBSListItem *mybbs;
  46.     struct List *conflist;
  47.     struct List *farealist;
  48.     ULONG msgnr;
  49.     ULONG replyto;
  50.     TEXT from[NAMELENGTH];
  51.     TEXT to[NAMELENGTH];
  52.     TEXT confname[NAMELENGTH];
  53.     TEXT subject[NAMELENGTH];
  54.     BOOL private;
  55.     BOOL read;
  56.     ULONG time;
  57.     struct MinList linelist;
  58.     ULONG lines;
  59.     BPTR fh;
  60.     STRPTR errmsg;
  61.     APTR msgpool;
  62.     APTR confpool;
  63.     APTR pbar;
  64.     STRPTR pubscreen;
  65. };
  66.  
  67. #define SysBase        td->SysBase
  68. #define DOSBase        td->DOSBase
  69. #define UtilityBase    td->UtilityBase
  70. #define BBSReadBase    td->BBSReadBase
  71. #define UTGuiBase        td->UTGuiBase
  72. #define mybbs            td->mybbs
  73. #define conflist        td->conflist
  74. #define farealist        td->farealist
  75. #define msgnr            td->msgnr
  76. #define replyto        td->replyto
  77. #define from            td->from
  78. #define to                td->to
  79. #define confname        td->confname
  80. #define subject        td->subject
  81. #define private        td->private
  82. #define read            td->read
  83. #define time            td->time
  84. #define linelist        td->linelist
  85. #define lines            td->lines
  86. #define fh                td->fh
  87. #define errmsg            td->errmsg
  88. #define msgpool        td->msgpool
  89. #define confpool        td->confpool
  90. #define pbar            td->pbar
  91. #define pubscreen        td->pubscreen
  92.  
  93.  
  94. extern STRPTR progname, progdate;
  95. extern LONG version, revision;
  96.  
  97. /*  Prototypes for external functions  */
  98. extern void * __asm AsmCreatePool(register __d0 ULONG, register __d1 ULONG, register __d2 ULONG, register __a6 struct ExecBase *);
  99. extern void __asm AsmDeletePool(register __a0 void *, register __a6 struct ExecBase *);
  100. extern void * __asm AsmAllocPooled(register __a0 void *, register __d0 ULONG, register __a6 struct ExecBase *);
  101. extern void __asm AsmFreePooled(register __a0 void *, register __a1 void *, register __d0 ULONG, register __a6 struct ExecBase *);
  102.  
  103. extern APTR SPrintf(STRPTR dest, STRPTR fmtstr, ...);
  104. extern struct Library *OpenBRLibrary(struct ExecBase *, struct DosLibrary *, STRPTR, LONG);
  105.  
  106. /*  Prototypes for global functions  */
  107. struct Node * FindiName(struct List *list, STRPTR name);
  108. BOOL DoMsgAdding(struct TaskData *td);
  109. BOOL ParseConfList(struct TaskData *td);
  110. BOOL ParseFileList(struct TaskData *td);
  111. STRPTR MyStrTok(STRPTR *tokptr, STRPTR input);
  112. UBYTE *StripAnsi(UBYTE *s);
  113.  
  114. STRPTR monthnames[] = 
  115. { 
  116.     "January", "February", "March", 
  117.     "April", "May", "June", 
  118.     "July", "August", "September", 
  119.     "October", "November", "December" 
  120. };
  121.  
  122. UBYTE *template = "BBSNAME,GRAB,PUBSCREEN/K,ARCHIVE/S,DELETE/S,USAGE/S";
  123.  
  124. enum {
  125.     TEM_BBSNAME,
  126.     TEM_GRAB,
  127.     TEM_PUBSCREEN,
  128.     TEM_ARCHIVE,
  129.     TEM_DELETE,
  130.     TEM_USAGE,
  131.     TEM_NUMBEROF
  132. };
  133.  
  134. STRPTR fmtstr =
  135. "%s V%ld.%ld\n"
  136. "Usage: %s [bbsname] [grab] [PubScreen name] [ARCHIVE] [DELETE] [USAGE]\n"
  137. "Copyright © Ultima Thule Software %s  Author: Eivind Nordseth\n%s";
  138.  
  139. LONG __saveds NoName(void)
  140. {
  141.     struct TaskData TaskData, *td;
  142.     struct GlobalConfig *cfg = NULL;
  143.     struct ConfListItem *myconf;
  144.     struct RDArgs *rdargs = NULL, *args = NULL;
  145.     BOOL newmsg = FALSE, findsubject = FALSE, getlines = FALSE, bufCopyBack = FALSE, addedMsgs = FALSE;
  146.     LONG array[TEM_NUMBEROF], retval = RETURN_FAIL, len, filelen, filepos;
  147.     struct List *bbslist = NULL;
  148.     STRPTR strp, foo, grab = NULL;
  149.     struct MinNode *node;
  150.     TEXT buf[BUFLEN], grabname[GRABLEN], tmpfile[GRABLEN];
  151.     BPTR lock, tmpfh = NULL;
  152.     UWORD charset;
  153.     
  154.     setmem(td = &TaskData, sizeof(struct TaskData), 0);
  155.     SysBase = *(struct ExecBase **)4;
  156.  
  157.     if(!(DOSBase = (struct DosLibrary *) OpenLibrary(DOSNAME, 0L))) return(10000L);
  158.     if(DOSBase->dl_lib.lib_Version < 37)
  159.     {
  160.         errmsg = "Needs Kick V37+";
  161.         goto quit;
  162.     }
  163.     if(!(UtilityBase = OpenLibrary("utility.library", 37L))) goto quit;
  164.  
  165.     if(!(BBSReadBase = OpenBRLibrary(SysBase, DOSBase, BBSREADNAME, 3L)))
  166.     {
  167.         errmsg = "Needs bbsread.library V3+";
  168.         goto quit;
  169.     }
  170.  
  171.     UTGuiBase = OpenBRLibrary(SysBase, DOSBase, "utgui.library", 1L);
  172.  
  173.     if(!(args = AllocDosObject(DOS_RDARGS, NULL))) goto quit;
  174.     setmem(array, TEM_NUMBEROF * sizeof(LONG), 0);
  175.  
  176.     SPrintf(args->RDA_ExtHelp = buf, fmtstr, progname, version, revision, 
  177.         progname, progdate, template);
  178.  
  179.     if(!(rdargs = ReadArgs(template, array, args)))
  180.     {
  181.         errmsg = "Error in arguments.";
  182.         goto quit;
  183.     }
  184.  
  185.     if(array[TEM_USAGE] || !array[TEM_BBSNAME] || !array[TEM_GRAB]) 
  186.     {
  187.         Printf(fmtstr, progname, version, revision, progname, progdate, "");
  188.         retval = RETURN_OK;
  189.         goto quit;
  190.     }
  191.     
  192.     pubscreen = (STRPTR) array[TEM_PUBSCREEN];
  193.  
  194.     if(!(cfg = GetGlobalConfig())) { errmsg = "Error geting global config."; goto quit; }
  195.  
  196.     if(!(ConfigGlobalTags(cfg, CG_BufCopyBack, TRUE, TAG_END))) { errmsg = "Error changing global config."; goto quit; }
  197.     bufCopyBack = TRUE;
  198.         
  199.     if(!(bbslist = GetBBSList())) { errmsg = "Error geting bbslist."; goto quit; }
  200.  
  201.     if(!(mybbs = (struct BBSListItem *) FindiName(bbslist, (STRPTR) array[TEM_BBSNAME])))
  202.     {
  203.         errmsg = "Unknown BBS";
  204.         goto quit;
  205.     }
  206.     StartOfAdding(mybbs);
  207.  
  208.     if(mybbs->bl_Data->bd_Flags & BDF_ADD_USERS)
  209.     {
  210.         WriteBRUserTags(mybbs, WBRUSR_OnlyIfNotExist, TRUE, BRUSR_Name, "SYSOP", TAG_END);
  211.     }
  212.  
  213.     if(!(conflist = GetConfList(mybbs))) { errmsg = "Error geting conflist."; goto quit; }
  214.  
  215.     if(ParseConfList(td)) goto quit;
  216.     if(ParseFileList(td)) goto quit;
  217.  
  218.     if(!(confpool = AsmCreatePool(MEMF_ANY, 1024, 512, SysBase)))
  219.     {
  220.         errmsg = "Out of memory";
  221.         goto quit;
  222.     }
  223.  
  224.  
  225. /* Make a copy of all confnames in the correct conference charset. */
  226.  
  227.     myconf = (struct ConfListItem *) &conflist->lh_Head;
  228.     
  229.     while((myconf = (struct ConfListItem *)myconf->cl_Node.ln_Succ)->cl_Node.ln_Succ)
  230.     {
  231.         if((charset = ConfCharset(mybbs, myconf)) != BRCS_ISO) 
  232.         {
  233.             if(!(myconf->cl_Node.ln_Name = AsmAllocPooled(confpool, 
  234.                 strlen(myconf->cl_Node.ln_Name) + 1, SysBase))) 
  235.             {
  236.                 errmsg = "Out of memory";
  237.                 goto quit;
  238.             }
  239.             CharsetConvert(BRCS_ISO, charset, myconf->cl_Data->cd_Name, 
  240.                 myconf->cl_Node.ln_Name, 0);
  241.         }
  242.     }
  243.  
  244.     if(!(lock = Lock((STRPTR) array[TEM_GRAB], ACCESS_READ)))
  245.     {
  246.         errmsg = "No grabfile"; 
  247.         goto done;
  248.     }
  249.     UnLock(lock);
  250.  
  251.     if(array[TEM_ARCHIVE]) 
  252.     {
  253.         if(pubscreen && UTGuiBase)
  254.         {
  255.             if(!pbar)
  256.             {
  257.                 if(!(pbar = ugOpenProgressBar(progname, 
  258.                     PB_Total, 1, 
  259.                     PB_ScreenName, pubscreen, 
  260.                     PB_AbortText, "_Abort",
  261.                     PB_ProgressText, "Unarchiving grab",
  262.                     PB_ProgressCWidth, 23,
  263.                     TAG_END)))
  264.                 {
  265.                     errmsg = "Coundn't open progress bar";
  266.                     goto quit;
  267.                 }
  268.             }
  269.             else
  270.             {
  271.                 if(ugUpdateProgressBar(pbar,
  272.                     PB_Total, 1,
  273.                     PB_Current, 0,
  274.                     PB_ProgressText, "Unarchiving grab",
  275.                     TAG_END)) goto done;
  276.             }
  277.  
  278.             SPrintf(tmpfile, "t:ParseMsg.%08lx", FindTask(NULL));
  279.  
  280.             tmpfh = Open(tmpfile, MODE_NEWFILE);
  281.         }
  282.     
  283.         if(UnArchiveTags((STRPTR) array[TEM_GRAB], 
  284.             UA_DestDir, mybbs->bl_BBSPath, 
  285.             tmpfh ? SYS_Output : TAG_IGNORE, tmpfh,
  286.             TAG_END))
  287.         {
  288.             if(tmpfh)
  289.             {
  290.                 Seek(tmpfh, 0, OFFSET_BEGINNING);
  291.                 
  292.                 while(FGets(tmpfh, buf, BUFLEN - 1)) FPuts(Output(), buf);
  293.             }
  294.  
  295.             errmsg = "Couldn't unarchive archive";
  296.             goto quit;
  297.         }
  298.         
  299.         strncpy(grabname, mybbs->bl_BBSPath, GRABLEN);
  300.         AddPart(grabname, mybbs->bl_Data->bd_GrabName, GRABLEN);
  301.  
  302.         grab = grabname;
  303.     }
  304.     else     grab = (STRPTR) array[TEM_GRAB];
  305.     
  306.     if(fh) Close(fh);
  307.     if(!(fh = Open(grab, MODE_OLDFILE)))
  308.     {
  309.         errmsg = "Unable to open grabfile";
  310.         goto quit;
  311.     }
  312.     
  313.     Seek(fh, 0, OFFSET_END);
  314.     if((filelen = Seek(fh, 0, OFFSET_BEGINNING)) == -1)
  315.     {
  316.         errmsg = "Seek error";
  317.         goto quit;
  318.     }
  319.     filepos = 0;
  320.  
  321.     if(pubscreen && UTGuiBase)
  322.     {
  323.         if(!pbar)
  324.         {
  325.             if(!(pbar = ugOpenProgressBar(progname, 
  326.                 PB_Total, filelen, 
  327.                 PB_ScreenName, pubscreen, 
  328.                 PB_AbortText, "_Abort",
  329.                 PB_ProgressText, "Parsing messages",
  330.                 PB_ProgressCWidth, 23,
  331.                 TAG_END)))
  332.             {
  333.                 errmsg = "Coundn't open progress bar";
  334.                 goto quit;
  335.             }
  336.         }
  337.         else
  338.         {
  339.             if(ugUpdateProgressBar(pbar,
  340.                 PB_Total, filelen,
  341.                 PB_Current, filepos,
  342.                 PB_ProgressText, "Parsing messages",
  343.                 TAG_END)) goto done;
  344.         }
  345.     }
  346.     else PutStr(CSI "0 p\n\n\n\n");
  347.  
  348.     NewList((struct List *)&linelist);
  349.     if(!(msgpool = AsmCreatePool(MEMF_ANY, 1024, 512, SysBase)))
  350.     {
  351.         errmsg = "Out of memory";
  352.         goto quit;
  353.     }
  354.  
  355.     while(FGets(fh, buf, BUFLEN - 1))
  356.     {
  357.         filepos += strlen(buf);
  358.  
  359.         if(findsubject)
  360.         {
  361.             if(!strncmp(buf, "   Entered on ",14))
  362.             {
  363.                 struct ClockData cd[1];
  364.  
  365.                 setmem(cd, sizeof(struct ClockData), '\0');
  366.  
  367.                 if(!isdigit(*(strp = &buf[14]))) 
  368.                 {
  369.                     while(*strp != ' ') if(!*(++strp)) goto datefail;     /* Spool over ABBS day    */
  370.                     if(*strp) strp++;
  371.                 }
  372.  
  373.                 cd->mday = atol(strp);
  374.                 while(*strp != ' ') if(!*(++strp)) goto datefail;    /* Spool over date str    */
  375.  
  376.                 if(!*(foo = ++strp)) goto datefail;
  377.  
  378.                 while(*strp != ' ') if(!*(++strp)) goto datefail;    /* Spool over month str    */
  379.                 if(strp[-1] == ',') strp[-1] = '\0';
  380.                 *strp = '\0';
  381.  
  382.                 for(cd->month = 0; cd->month < 12; cd->month++)
  383.                     if(!strcmp(foo, monthnames[cd->month])) break;
  384.         
  385.                 if(cd->month++ == 12) goto datefail;
  386.                 
  387.                 if(!*(++strp)) goto datefail;
  388.  
  389.                 cd->year = atol(strp);
  390.  
  391.                 while(*strp != ' ') if(!*(++strp)) goto datefail;    /* Spool over year        */
  392.                 
  393.                 if(!strncmp(strp, " at ", 4))
  394.                 {
  395.                     strp += 4;
  396.                     strp[2] = '\0';
  397.                     strp[5] = '\0';
  398.                     cd->hour = atol(strp);
  399.                     cd->min = atol(strp + 3);    /* Calculate time        */
  400.                 }
  401.  
  402.                 time = Date2Amiga(cd);
  403. datefail:
  404.                 charset = 0;
  405.             }
  406.             if(!strncmp(buf, "   Reply to msg",15))
  407.             {
  408.                 strp = &buf[18];
  409.  
  410.                 while(*strp != '.') if(!*(strp++)) break;
  411.                 *strp = '\0';
  412.                 replyto = atol(&buf[18]);
  413.             }
  414.             if(!strncmp(buf, "Subject: ",9))
  415.             {
  416.                 stccpy(subject, &buf[9], NAMELENGTH);
  417.                 if(subject[strlen(subject) - 2] == '\r') subject[strlen(subject) - 2] = '\0';
  418.                 findsubject = FALSE;
  419.                 getlines = TRUE;
  420.                 lines = 0;
  421.                 FGets(fh, buf, BUFLEN - 1);
  422.                 filepos += strlen(buf);
  423.                 FGets(fh, buf, BUFLEN - 1);
  424.                 filepos += strlen(buf);
  425.                 continue;
  426.             }
  427.         }
  428.         if(newmsg) 
  429.         {
  430. /*            FPuts(Output(), buf);  */
  431.             
  432.             confname[0] = to[0] = from[0] = '\0';
  433.             msgnr = ULONG_MAX;
  434.             private = FALSE;
  435.             read = FALSE;
  436.             time = 0 ;
  437.  
  438.             strp = buf;
  439.             do 
  440.             {
  441.                 if(!*(++strp)) goto line1fail;
  442.                 while(*strp != ' ') if(!*(++strp)) goto line1fail;
  443.             } while(strncmp(strp, " message",8));
  444.  
  445.             *strp = '\0';
  446.  
  447.             stccpy(confname, buf, NAMELENGTH);
  448.  
  449.             while(*strp != '#') if(!*(++strp)) goto line1fail;
  450.  
  451.             if(!*(foo = ++strp)) goto line1fail;
  452.             while(*strp != ' ') if(!*(++strp)) goto line1fail;
  453.             *strp = '\0';
  454.             msgnr = atol(foo);
  455.  
  456.             while(*strp != ' ') if(!*(++strp)) goto line1fail;
  457.             if(!*(foo = ++strp)) goto line1fail;
  458.  
  459.             do 
  460.             {
  461.                 if(!*(++strp)) goto line1fail;
  462.                 while(*strp != ' ') if(!*(++strp)) goto line1fail;
  463.             } while(strncmp(strp, " to ",4));
  464.             *strp = '\0';
  465.             stccpy(from, foo, NAMELENGTH);
  466.  
  467.             if(strlen(++strp) <= 3) goto line1fail;
  468.             foo = strp + 3;
  469.  
  470.             *(strp = foo + strlen(foo) - 2) = '\0';
  471.  
  472.             if(*(--strp) == '.')
  473.             {
  474.                 *strp = '\0';
  475.                 
  476.                 while(*(--strp) == ')')
  477.                 {
  478.                     while(*(--strp) != '(' && strp > foo);
  479.                     if(*(strp) != '(') break;
  480.  
  481.                     if(!stricmp(strp, "(PRIVATE)")) private = TRUE;
  482.                     if(!strcmp(strp, "(read)")) read = TRUE; 
  483.  
  484.                     if(read || private) *(--strp) = '\0';
  485.                     else break;
  486.                 }
  487.             }
  488.             
  489.             stccpy(to, foo, NAMELENGTH);
  490.  
  491. line1fail:            
  492.             if(!confname[0]) stccpy(confname, "No Conf", NAMELENGTH); 
  493.             if(!to[0])       stccpy(to, "Unknown", NAMELENGTH);
  494.             if(!from[0])     stccpy(from, "Unknown", NAMELENGTH); 
  495.  
  496.             newmsg = FALSE;
  497.             findsubject = TRUE;
  498.         }
  499.  
  500.         len = strlen(buf);
  501.         if(buf[len > 2 ? len - 3 : 0] == '\r' && buf[len > 2 ? len - 2 : 1] == '\r') 
  502.         {
  503.             if(msgnr)
  504.             {
  505.                 if(DoMsgAdding(td)) 
  506.                 {
  507.                     errmsg = "Failure when adding message";
  508.                     goto quit;
  509.                 }
  510.                 NewList((struct List *)&linelist);
  511.                 AsmDeletePool(msgpool, SysBase);
  512.                 if(!(msgpool = AsmCreatePool(MEMF_CLEAR, 1024, 512, SysBase)))
  513.                 {
  514.                     errmsg = "Out of memory";
  515.                     goto quit;
  516.                 }
  517.                 addedMsgs = TRUE;
  518.             }
  519.             newmsg = TRUE;
  520.             getlines = FALSE;
  521.         }
  522.  
  523.         if(getlines)
  524.         {
  525.             if(!(node = (struct MinNode *) AsmAllocPooled(msgpool, sizeof(struct MinNode) + 80, SysBase)))
  526.             {
  527.                 errmsg = "Out of memory";
  528.                 goto quit;
  529.             }
  530.             strp = (STRPTR) &node[1];
  531.             stccpy(strp, buf, 80);
  532.             if(strp[strlen(strp) - 2] == '\r') strp[strlen(strp) - 2] = '\0';
  533.             AddTail((struct List *)&linelist, (struct Node *) node);
  534.             lines++;            
  535.         }
  536.         if(SetSignal(0L,SIGBREAKF_CTRL_C) & SIGBREAKF_CTRL_C)
  537.         {
  538.             errmsg = "***Break";
  539.             goto done;
  540.         }
  541.         if(pbar) if(ugUpdateProgressBar(pbar, PB_Current, filepos, TAG_END)) goto done;
  542.     }
  543.     if(lines)
  544.     {
  545.         if(DoMsgAdding(td)) 
  546.         {
  547.             errmsg = "Failure when adding message";
  548.             goto quit;
  549.         }
  550.         addedMsgs = TRUE;
  551.     }
  552.  
  553.     if(fh) Close(fh);
  554.     fh = NULL;
  555.  
  556.     if(!addedMsgs) 
  557.     {
  558.         errmsg = "No messages to add";
  559.         goto quit;
  560.     }
  561.  
  562.     if(array[TEM_DELETE]) DeleteFile((STRPTR) array[TEM_GRAB]);
  563.  
  564. done:   /*  All stuff is done  */
  565.  
  566.     retval = RETURN_OK;
  567.  
  568.     Flush(Output());
  569.  
  570. quit:
  571.     if(pbar) ugCloseProgressBar(pbar);
  572.     else Write(Output(), CSI "1 p", 4); 
  573.  
  574.     if(tmpfh)
  575.     {
  576.         Close(tmpfh);
  577.         DeleteFile(tmpfile);
  578.     }
  579.  
  580.     if(errmsg)
  581.     {
  582.         struct ReqToolsBase *ReqToolsBase = NULL;
  583.  
  584.         if(pbar)
  585.         {
  586.             if(ReqToolsBase = (struct ReqToolsBase *) OpenLibrary(REQTOOLSNAME, 38))
  587.             {
  588.                 rtEZRequestTags(errmsg, "_OK", NULL, NULL, 
  589.                     RT_ReqPos, REQPOS_CENTERSCR,
  590.                     RT_PubScrName, pubscreen,
  591.                     RTEZ_ReqTitle, progname,
  592.                     RT_Underscore, '_',
  593.                     TAG_END);
  594.  
  595.                 CloseLibrary((struct Library *) ReqToolsBase);
  596.             }
  597.         }
  598.  
  599.         if(!ReqToolsBase)
  600.         {
  601.             Write(Output(), errmsg, strlen(errmsg));
  602.             Write(Output(), "\n", 1);
  603.         }
  604.     }
  605.     if(fh) Close(fh);
  606.     if(grab && array[TEM_ARCHIVE]) DeleteFile(grab);
  607.     if(cfg)
  608.     {
  609.         if(bufCopyBack) ConfigGlobalTags(cfg, CG_BufEndCopyBack, TRUE, TAG_END);
  610.         FreeBRObject(cfg);
  611.     }
  612.     if(mybbs) EndOfAdding(mybbs);
  613.  
  614.     if(bbslist)   FreeBRObject(bbslist);
  615.     if(conflist)  FreeBRObject(conflist);
  616.     if(farealist) FreeBRObject(farealist);
  617.  
  618.     if(rdargs) FreeArgs(rdargs);
  619.     if(args)   FreeDosObject(DOS_RDARGS, args);
  620.  
  621.     if(msgpool) AsmDeletePool(msgpool, SysBase);
  622.     if(confpool) AsmDeletePool(confpool, SysBase);
  623.     if(UTGuiBase)   CloseLibrary(UTGuiBase);
  624.     if(BBSReadBase) CloseLibrary(BBSReadBase);
  625.     if(UtilityBase) CloseLibrary(UtilityBase);
  626.     CloseLibrary((struct Library *) DOSBase);
  627.     return(retval);
  628. }
  629.  
  630.  
  631. struct Node * FindiName(
  632. struct List *list, 
  633. STRPTR name)
  634. {
  635.     struct Node *node = (struct Node *) &list->lh_Head;
  636.     
  637.     while((node = node->ln_Succ)->ln_Succ)
  638.     {
  639.         if(!stricmp(name, node->ln_Name)) return(node);
  640.     }
  641.     return(NULL);
  642. }
  643.  
  644. /*  returns error */
  645. BOOL DoMsgAdding(
  646. struct TaskData *td)
  647. {
  648.     struct ConfListItem *myconf;
  649.     ULONG n = 0L;
  650.     STRPTR *linearray;
  651.     struct MinNode *node;
  652.     BOOL error = TRUE;
  653.     UWORD charset;
  654.  
  655.     if(!lines) return(FALSE);
  656.  
  657.     if(!(myconf = (struct ConfListItem *) FindiName(conflist, confname)))
  658.     {
  659. /*        Printf("New conference!\n");  */
  660.  
  661.         if((charset = ConfCharset(mybbs, NULL)) != BRCS_ISO) 
  662.             if(!CharsetConvert(charset, BRCS_ISO, confname, NULL, 0L)) goto fail;
  663.  
  664.         if(!(myconf = ConfigConfTags(NULL, 
  665.             CC_ConfList, conflist, 
  666.             CC_AddToBBS, mybbs, 
  667.             CC_ConfName, confname, 
  668.             CC_SetConfFlags, CDF_MEMBER_OF,
  669.             TAG_END))) goto fail; 
  670.  
  671.         if(charset != BRCS_ISO) /* Convert conference name? */
  672.         {
  673.             if(!(myconf->cl_Node.ln_Name = AsmAllocPooled(confpool, 
  674.                 strlen(myconf->cl_Node.ln_Name) + 1, SysBase))) 
  675.             {
  676.                 errmsg = "Out of memory";
  677.                 goto fail;
  678.             }
  679.             CharsetConvert(BRCS_ISO, charset, myconf->cl_Data->cd_Name, 
  680.                 myconf->cl_Node.ln_Name, 0);
  681.         }
  682.     } 
  683.     else 
  684.     {
  685.         charset = ConfCharset(mybbs, myconf);
  686.  
  687.         if(!(myconf->cl_Data->cd_Flags & CDF_MEMBER_OF)) 
  688.             ConfigConfTags(myconf, CC_SetConfFlags, CDF_MEMBER_OF, TAG_END);
  689.     }
  690.  
  691.     if(!(linearray = AsmAllocPooled(msgpool, (lines + 1) * sizeof(STRPTR), SysBase))) return(TRUE);
  692.  
  693.     node = (struct MinNode *) &linelist.mlh_Head;
  694.     while((node = node->mln_Succ)->mln_Succ) 
  695.     {
  696.         linearray[n] = (STRPTR) &node[1]; 
  697.         if(charset != BRCS_ISO) CharsetConvert(charset, BRCS_ISO, linearray[n], NULL, 0);
  698.         n++;
  699. /*        Printf("line %ld of %ld:%s\n", n, lines, &node[1]); */
  700.     }
  701.     if(n) { linearray[--n] = NULL; }
  702.     if(n) { if(!strlen(linearray[--n])) linearray[n] = NULL; }
  703.  
  704.     if(charset != BRCS_ISO)
  705.     {
  706.         CharsetConvert(charset, BRCS_ISO, from, NULL, 0);    
  707.         CharsetConvert(charset, BRCS_ISO, to, NULL, 0);    
  708.         CharsetConvert(charset, BRCS_ISO, subject, NULL, 0);    
  709.     }
  710.     
  711.     if(!WriteBRMessageTags(myconf,
  712.         BRMSG_FromName, from,
  713.         (strcmp(to, "ALL") ? BRMSG_ToName : TAG_IGNORE), to,
  714.         BRMSG_OrginalNr, msgnr,
  715.         (replyto ? BRMSG_RefNr : TAG_IGNORE), replyto,
  716.         (time ? BRMSG_CreationDate : TAG_IGNORE), time,
  717.         BRMSG_Subject, subject,
  718.         BRMSG_Text, linearray,
  719.         WBRMSG_MarkMessage, TRUE,
  720.         WBRMSG_Private, private,
  721.         WBRMSG_Read, read,
  722.         TAG_END)) goto fail;
  723.  
  724.     if(mybbs->bl_Data->bd_Flags & BDF_ADD_USERS || private)
  725.     {
  726.         WriteBRUserTags(mybbs, WBRUSR_OnlyIfNotExist, TRUE, BRUSR_Name, from, TAG_END);
  727.  
  728.         if(strcmp(to, "ALL"))
  729.             WriteBRUserTags(mybbs, WBRUSR_OnlyIfNotExist, TRUE, BRUSR_Name, to, TAG_END);
  730.     }
  731.     error = FALSE;
  732.  
  733. fail:
  734.     if(!pbar || error)
  735.     {
  736.         if(!pbar) PutStr("\x9b\x34\x41");
  737.  
  738.         Printf("Conf: %-30.s\nMsgnr: %5.ld   Replyto: %5.ld\nFrom: %-30.s To: %-30.s\n", 
  739.             myconf->cl_Data->cd_Name, msgnr, replyto, from, to);
  740.         Printf("Subject: %-60.s\n", subject);
  741.     }
  742.     lines = 0; replyto = 0;
  743.     return(error);
  744. }
  745.  
  746. /****** parsemsg/ParseConfList ******************************************
  747. *
  748. *   NAME    
  749. *    ParseConfList -- Parses conference list.
  750. *
  751. *   SYNOPSIS
  752. *    error = ParseConfList( td )
  753. *
  754. *    BOOL ParseConfList( struct TaskData * );
  755. *
  756. *   FUNCTION
  757. *    Parses conferences.txt and updates the conference list for a bbs.
  758. *    Dependant of SysBase, DOSBase, UtilityBase, BBSReadBase, UTGuiBase,
  759. *    mybbs, pubscreen, pbar and conflist defined in the TaskData structure.
  760. *
  761. *   INPUTS
  762. *    td - TaskData structure.
  763. *
  764. *   RESULT
  765. *    error - Boolean.
  766. *        The errmsg field in TaskData may be set to point to an error
  767. *        message if the function fails.
  768. *
  769. *   EXAMPLE
  770. *
  771. *   NOTES
  772. *
  773. *   BUGS
  774. *
  775. *   SEE ALSO
  776. *
  777. ******************************************************************************
  778. *
  779. */
  780. BOOL ParseConfList(
  781. struct TaskData *td)
  782. {
  783.     struct ConfListItem *myconf, *nextconf;
  784.     struct PassConfListItem *passconf;
  785.     struct List list[1];
  786.     STRPTR foo, bits;
  787.     TEXT ct[BUFLEN], fname[GRABLEN];
  788.     BOOL bitdone, biterr, heading = TRUE, error = TRUE, delete = FALSE;
  789.     LONGBITS flags;
  790.     BPTR dofh = NULL;
  791.     APTR pool = NULL;
  792.     LONG filelen, filepos;
  793.  
  794.     strncpy(fname, mybbs->bl_BBSPath, GRABLEN);
  795.     strncat(fname, "conferences.txt", GRABLEN - strlen(fname));
  796.  
  797.     if(!(dofh = Open(fname, MODE_OLDFILE))) return(FALSE);
  798.     
  799.     Seek(dofh, 0, OFFSET_END);
  800.     if((filelen = Seek(dofh, 0, OFFSET_BEGINNING)) == -1)
  801.     {
  802.         errmsg = "Seek error";
  803.         goto fail;
  804.     }
  805.     filepos = 0;
  806.  
  807.     if(pubscreen && UTGuiBase)
  808.     {
  809.         if(!pbar)
  810.         {
  811.             if(!(pbar = ugOpenProgressBar(progname, 
  812.                 PB_Total, filelen, 
  813.                 PB_ScreenName, pubscreen, 
  814.                 PB_AbortText, "_Abort",
  815.                 PB_ProgressText, "Parsing conference list",
  816.                 PB_ProgressCWidth, 23,
  817.                 TAG_END)))
  818.             {
  819.                 errmsg = "Coundn't open progress bar";
  820.                 goto fail;
  821.             }
  822.         }
  823.         else
  824.         {
  825.             if(ugUpdateProgressBar(pbar,
  826.                 PB_Total, filelen,
  827.                 PB_Current, filepos,
  828.                 PB_ProgressText, "Parsing conference list",
  829.                 TAG_END)) goto done;
  830.         }
  831.     }
  832.     else PutStr(CSI"0 p\n");
  833.  
  834.     NewList(list);
  835.     if(!(pool = AsmCreatePool(MEMF_ANY, 512, 256, SysBase)))
  836.     {
  837.         errmsg = "Out of memory";
  838.         goto fail;
  839.     }
  840.  
  841.     while(FGets(dofh, ct, BUFLEN - 1))
  842.     {
  843.         filepos += strlen(ct);
  844.         StripAnsi(ct);
  845.  
  846.         if(heading)
  847.         {
  848.             if(!(strcmp(ct, "-----------------"))) heading = FALSE;
  849.             continue;
  850.         }
  851.         bits = ct;
  852.         while(*bits != ':') if(!*(++bits)) break;
  853.         if(!*bits) continue;
  854.  
  855.         *bits = '\0';
  856.         foo = bits++ - 1;
  857.  
  858.         while(foo > ct && *foo == ' ') *(foo--) = '\0';
  859.         if(foo == ct) continue;
  860.         
  861.         bitdone = FALSE;
  862.         biterr = FALSE;
  863.         flags = 0;
  864.         while(!bitdone)
  865.         {
  866.             foo = ++bits;
  867.             
  868.             while(*foo && *foo != '.' && *foo != ',') foo++;
  869.             if(!*foo) 
  870.             {
  871.                 biterr = TRUE;
  872.                 break;
  873.             }
  874.             if(*foo == '.') bitdone = TRUE;
  875.             *(foo++) = '\0';
  876.             
  877.             if(!strcmp(bits, "MAIL"))            flags |= CDF_MAIL;
  878.             if(!strcmp(bits, "READ ONLY"))       flags |= CDF_READ_ONLY;
  879.             if(!strcmp(bits, "Obligatory"))      flags |= CDF_COMPULSORY;
  880.             if(!strcmp(bits, "FILE INFO"))       flags |= CDF_FILE_INFO;
  881.             if(!strcmp(bits, "USER INFO"))       flags |= CDF_USER_INFO;
  882.             if(!strcmp(bits, "Private allowed")) flags |= CDF_PRIVATE_ALLOWED;
  883.             if(!strcmp(bits, "Member"))          flags |= CDF_MEMBER_OF;
  884.             if(!strcmp(bits, "Alias"))           flags |= CDF_ALIAS | CDF_ENTER_ONLY_TO_ALL;
  885.             bits = foo;
  886.         }
  887.         if(biterr) continue;
  888.         
  889.         if(!(passconf = AsmAllocPooled(pool, sizeof(struct PassConfListItem) + strlen(ct) + 1, SysBase)))
  890.         {
  891.             errmsg = "Out of memory";
  892.             goto fail;
  893.         }
  894.         strcpy(passconf->pl_Name = passconf->pl_Node.ln_Name = (STRPTR) &passconf[1], ct);
  895.         passconf->pl_Description = NULL;
  896.         passconf->pl_BBSConfNr   = -1;
  897.         passconf->pl_Flags       = flags;
  898.         AddTail(list, (struct Node *) passconf);
  899.  
  900.         if(!pbar)
  901.         {
  902.             PutStr(CSI "A");
  903.             Printf("Conf: %-30.s, Flags: %l08x\n", ct, flags);
  904.         }
  905.  
  906.         if((myconf = (struct ConfListItem *) FindiName(conflist, ct)) || (flags & CDF_MEMBER_OF))
  907.         {
  908.             if(!(myconf = ConfigConfTags(myconf, CC_ConfList, conflist, 
  909.                 CC_AddToBBS, mybbs, CC_ConfName, ct, CC_ClearConfFlags, 
  910.                 CDF_MEMBER_OF | CDF_MAIL | CDF_READ_ONLY | CDF_COMPULSORY | CDF_FILE_INFO 
  911.                 | CDF_USER_INFO | CDF_PRIVATE_ALLOWED | CDF_ENTER_ONLY_TO_ALL | CDF_ALIAS
  912.                 | CDF_NOT_ON_BBS | CDF_REPLY_ONLY_TO_ALL | CDF_NO_LINEWRAP_DISPLAY, 
  913.                 CC_SetConfFlags, flags, TAG_END)))
  914.             {
  915.                 if(pbar) Printf("Conf: %-30.s, Flags: %l08x\n", ct, flags);
  916.     
  917.                 errmsg = "ConfigConf() failed";
  918.                 goto fail;
  919.             }
  920.             myconf->cl_UserData = (APTR) TRUE;
  921.         }
  922.         if(SetSignal(0L,SIGBREAKF_CTRL_C) & SIGBREAKF_CTRL_C)
  923.         {
  924.             errmsg = "***Break";
  925.             goto done;
  926.         }
  927.         if(pbar) if(ugUpdateProgressBar(pbar, PB_Current, filepos, TAG_END)) goto done;
  928.     }
  929.  
  930.     nextconf = (struct ConfListItem *) conflist->lh_Head;
  931.  
  932.     while(nextconf = (struct ConfListItem *) (myconf = nextconf)->cl_Node.ln_Succ)
  933.     {
  934.         struct ConfInternal *confint = myconf->cl_Internal;
  935.  
  936.         if(confint->ci_LastMsg < confint->ci_FirstMsg  
  937.             && (!(myconf->cl_Data->cd_Flags & CDF_MEMBER_OF) || !myconf->cl_UserData))
  938.         {
  939.             ConfigConfTags(myconf, CC_DeleteConf, TRUE, TAG_END);
  940.         }
  941.         else 
  942.         {
  943.             if(!myconf->cl_UserData) 
  944.                 ConfigConfTags(myconf, 
  945.                     CC_SetConfFlags, CDF_NOT_ON_BBS, 
  946.                     CC_ClearConfFlags, CDF_MEMBER_OF, 
  947.                     TAG_END);
  948.         }
  949.     }
  950.  
  951.     if(WritePassiveConfList(mybbs, list))
  952.     {
  953.         errmsg = "WritePassiveConfList() failed";
  954.         goto fail;
  955.     }
  956.  
  957.     delete = TRUE;
  958. done:
  959.     error = FALSE;
  960. fail:
  961.     if(pool) AsmDeletePool(pool, SysBase);
  962.     if(dofh) Close(dofh);
  963.     if(delete) DeleteFile(fname);
  964.  
  965.     return(error);
  966. }
  967.  
  968. /****** parsemsg/ParseFileList ******************************************
  969. *
  970. *   NAME    
  971. *    ParseFileList -- Adds files from newfiles.txt to the file database.
  972. *
  973. *   SYNOPSIS
  974. *    error = ParseFileList( td )
  975. *
  976. *    BOOL ParseFileList( struct TaskData * );
  977. *
  978. *   FUNCTION
  979. *    Parses newfiles.txt and adds new files to the database. Dependant of
  980. *    SysBase, DOSBase, UtilityBase, BBSReadBase, UTGuiBase, mybbs,
  981. *    pubscreen, pbar and farealist defined in the TaskData structure.
  982. *
  983. *   INPUTS
  984. *    td - TaskData structure.
  985. *
  986. *   RESULT
  987. *    error - Boolean.
  988. *        The errmsg field in TaskData may be set to point to an error
  989. *        message if the function fails.
  990. *
  991. *   EXAMPLE
  992. *
  993. *   NOTES
  994. *
  995. *   BUGS
  996. *
  997. *   SEE ALSO
  998. *
  999. ******************************************************************************
  1000. *
  1001. */
  1002. BOOL ParseFileList(
  1003. struct TaskData *td)
  1004. {
  1005.     struct FAreaListItem *farea = NULL;
  1006.     struct SFileResult *found;
  1007.     struct ClockData cd[1];
  1008.     TEXT ct[BUFLEN], fname[GRABLEN];
  1009.     BOOL error = TRUE, back = FALSE;
  1010.     STRPTR file, date, kb, min, dlds, descr[2], np;
  1011.     BPTR dofh = NULL;
  1012.     LONG cnt, filelen, filepos;
  1013.  
  1014.     strncpy(fname, mybbs->bl_BBSPath, GRABLEN);
  1015.     AddPart(fname, "Newfiles.txt", GRABLEN);
  1016.  
  1017.     if(!(dofh = Open(fname, MODE_OLDFILE))) return(FALSE);
  1018.     
  1019.     Seek(dofh, 0, OFFSET_END);
  1020.     if((filelen = Seek(dofh, 0, OFFSET_BEGINNING)) == -1)
  1021.     {
  1022.         errmsg = "Seek error";
  1023.         goto fail;
  1024.     }
  1025.  
  1026.     if(FGets(dofh, ct, BUFLEN - 1)) 
  1027.     {
  1028.         if(!strcmp(ct, "DONE\n")) goto done;
  1029.     }
  1030.     filepos = 5;
  1031.  
  1032.     if(pubscreen && UTGuiBase)
  1033.     {
  1034.         if(!pbar)
  1035.         {
  1036.             if(!(pbar = ugOpenProgressBar(progname, 
  1037.                 PB_Total, filelen, 
  1038.                 PB_ScreenName, pubscreen, 
  1039.                 PB_AbortText, "_Abort",
  1040.                 PB_ProgressText, "Parsing newfiles",
  1041.                 PB_ProgressCWidth, 23,
  1042.                 TAG_END)))
  1043.             {
  1044.                 errmsg = "Coundn't open progress bar";
  1045.                 goto fail;
  1046.             }
  1047.         }
  1048.         else
  1049.         {
  1050.             if(ugUpdateProgressBar(pbar,
  1051.                 PB_Total, filelen,
  1052.                 PB_Current, filepos,
  1053.                 PB_ProgressText, "Parsing newfiles",
  1054.                 TAG_END)) goto done;
  1055.         }
  1056.     }
  1057.     else PutStr(CSI"0 p\n");
  1058.  
  1059.     if(!(farealist = GetFAreaList(mybbs))) 
  1060.     { 
  1061.         errmsg = "GetFAreaList() failed";
  1062.         goto fail;
  1063.     }
  1064.  
  1065.     while(FGets(dofh, ct, BUFLEN - 1))
  1066.     {
  1067.         BOOL notdigit = FALSE;
  1068.  
  1069.         filepos += strlen(ct);
  1070.         StripAnsi(ct);
  1071.  
  1072.         if(ct[0] == '(')
  1073.         {
  1074.             LONG len = strlen(ct) - 1;
  1075.             
  1076.             if(ct[len] != ')') continue;
  1077.  
  1078.             if(len > 1) 
  1079.             {
  1080.                 ct[len] = '\0';
  1081.                 
  1082.                 strcpy(fname, &ct[1]);
  1083.                 
  1084.                 if(!(farea = (struct FAreaListItem *) FindiName(farealist, fname)))
  1085.                 {
  1086.                     if(!(farea = ConfigFAreaTags(NULL, 
  1087.                         CFA_FAreaList, farealist,
  1088.                         CFA_AddToBBS, mybbs,
  1089.                         CFA_Name, fname, TAG_END))) 
  1090.                     { 
  1091.                         errmsg = "ConfigFArea() failed"; 
  1092.                         goto fail;
  1093.                     }
  1094.                 }
  1095.                 cnt = 3;        /* Skip farea header */
  1096.             }
  1097.             else farea = NULL;
  1098.  
  1099.             continue;
  1100.         }
  1101.         if(!farea) continue;
  1102.         if(cnt) if(cnt--) continue;
  1103.         
  1104.         if(strlen(ct) < 40) continue;
  1105.         
  1106.         if(!(np = MyStrTok(&file, &ct[2])))   continue;
  1107.         if(!(np = MyStrTok(&date, np)))       continue;
  1108.         if(!(np = MyStrTok(&kb, np)))         continue;
  1109.         if(!(np = MyStrTok(&min, np)))        continue;
  1110.         if(!(descr[0] = MyStrTok(&dlds, np))) continue;
  1111.         descr[1] = NULL;
  1112.         
  1113.         for(np = date; *np; np++) 
  1114.             if(!isdigit(*np)) 
  1115.                 notdigit = TRUE;
  1116.  
  1117.         if(!isdigit(*kb)) notdigit = TRUE;
  1118.  
  1119.         if(!isdigit(*min)) notdigit = TRUE;
  1120.  
  1121.         for(np = dlds; *np; np++)  
  1122.             if(!isdigit(*np)) 
  1123.                 notdigit = TRUE;
  1124.  
  1125.         if(SetSignal(0L,SIGBREAKF_CTRL_C) & SIGBREAKF_CTRL_C)
  1126.         {
  1127.             errmsg = "***Break";
  1128.             goto done;
  1129.         }
  1130.         if(pbar) if(ugUpdateProgressBar(pbar, PB_Current, filepos, TAG_END)) goto done;
  1131.  
  1132.         if(!descr[0] || notdigit) continue;
  1133.  
  1134.         if(found = SearchBRFileTags(
  1135.             SBRF_SearchFAreaList, farealist,
  1136.             SBRF_SearchStr, file,
  1137.             SBRF_SearchName, TRUE,
  1138.             SBRF_SearchAll, FALSE,
  1139.             TAG_END))
  1140.         {
  1141.             if(found->fr_FilesFound)
  1142.             {
  1143.                 if(found->fr_Files[0].ff_FArea == farea) 
  1144.                 {
  1145.                     APTR obj;
  1146.                     struct TagItem *tags;
  1147.                     BOOL equal = FALSE;
  1148.  
  1149.                     if(obj = ReadBRFileTags(found->fr_Files[0].ff_FArea, found->fr_Files[0].ff_FileNr,
  1150.                         RBRF_FileTagsPtr, &tags, TAG_END))
  1151.                     {
  1152.                         if(atol(dlds) == GetTagData(BRFILE_Downloads, 0, tags)) equal = TRUE;
  1153.                         FreeBRObject(obj);
  1154.                     }
  1155.                     if(equal == TRUE) continue;
  1156.                 }
  1157.             
  1158.                 WriteBRFileTags(farea, 
  1159.                     WBRF_UpdateFileNr, found->fr_Files[0].ff_FileNr,
  1160.                     WBRF_DeleteFile, TRUE,
  1161.                     TAG_END);
  1162.             }
  1163.             FreeBRObject(found);
  1164.         }
  1165.  
  1166.         setmem(cd, sizeof(struct ClockData), '\0');
  1167.         cd->mday = atol(&date[4]);
  1168.         date[4] = '\0';
  1169.         cd->month = atol(&date[2]);
  1170.         date[2] = '\0';
  1171.         cd->year = atol(date);
  1172.         if(cd->year < 78) cd->year += 2000;
  1173.         else cd->year += 1900;
  1174.  
  1175.         time = Date2Amiga(cd);
  1176.  
  1177.         if(!pbar)
  1178.         {
  1179.             if(back) PutStr(CSI "2A"); 
  1180.             back = TRUE;
  1181.  
  1182.             Printf("Farea: %-20.s File:%-16.s\nDescr: %-40.s\n", 
  1183.                 farea->al_Data->ad_Name, file, descr[0]);
  1184.         }
  1185.  
  1186.         if(!WriteBRFileTags(farea, 
  1187.             BRFILE_Name, file,
  1188.             BRFILE_Date, time, 
  1189.             BRFILE_Size, atol(kb) * 1024,
  1190.             BRFILE_Downloads, atol(dlds),
  1191.             BRFILE_Description, descr, TAG_END))
  1192.         { 
  1193.             if(pbar) Printf("Farea: %-20.s File:%-16.s\nDescr: %-40.s\n", 
  1194.                             farea->al_Data->ad_Name, file, descr[0]);
  1195.  
  1196.             errmsg = "WriteBRFile() failed"; 
  1197.             goto fail;
  1198.         }
  1199.     }
  1200.  
  1201.     Seek(dofh, 0 , OFFSET_BEGINNING);
  1202.     FPuts(dofh, "DONE\n"); 
  1203.  
  1204. done:
  1205.     error = FALSE;
  1206. fail:
  1207.     if(dofh) Close(dofh);
  1208.     
  1209.     return(error);
  1210. }
  1211.  
  1212. STRPTR MyStrTok(
  1213. STRPTR *tokptr,
  1214. STRPTR input)
  1215. {
  1216.     *tokptr = NULL;
  1217.     if(!input) return(NULL);
  1218.  
  1219.     while(*input && *input == ' ') input++;
  1220.     if(!*input) return(NULL);
  1221.  
  1222.     *tokptr = input;
  1223.     while(*input && *input != ' ') input++;
  1224.  
  1225.     if(!*input) return(NULL);
  1226.  
  1227.     *input = '\0';
  1228.     
  1229.     return(input + 1);
  1230. }
  1231.  
  1232. UBYTE *StripAnsi(UBYTE *s)
  1233. {
  1234.     STRPTR dest = s, d = s;
  1235.     
  1236.     while(*s)    
  1237.     {
  1238.         if((*s == 0x1b) || (*s == 0x9b))
  1239.         {
  1240.             if(*s == 0x1b)
  1241.             {
  1242.                 if(*++s != '[') continue;
  1243.             }
  1244.             s++;
  1245.             while(*s && *s < '@') s++;
  1246.         }
  1247.         else if(*s >= 32) *d++ = *s;
  1248.         s++;
  1249.     }
  1250.     *d = '\0';
  1251.  
  1252.     return(dest);
  1253. }
  1254.